//package com.zpark.it.listener;
//
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.fasterxml.jackson.databind.ObjectMapper;
//import com.zpark.it.doc.ProductDoc;
//import com.zpark.it.pojo.Product;
//import org.elasticsearch.action.delete.DeleteRequest;
//import org.elasticsearch.action.index.IndexRequest;
//import org.elasticsearch.client.RequestOptions;
//import org.elasticsearch.client.RestHighLevelClient;
//import org.elasticsearch.common.xcontent.XContentType;
//import org.springframework.amqp.rabbit.annotation.Exchange;
//import org.springframework.amqp.rabbit.annotation.Queue;
//import org.springframework.amqp.rabbit.annotation.QueueBinding;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import java.io.IOException;
//
///**
// * @Title: RabbitMqListener 监听消息通知
// * @Author Charles
// * @Package com.zpark.it.listener
// * @Date 2023/7/23 21:51
// */
//@Component
//public class RabbitMqListener {
//    @Autowired
//    private RestHighLevelClient restHighLevelClient;
//    /**
//     * 监听并且插入数据的方法
//     */
//    //绑定这是插入信息
//
//
//    @RabbitListener(
//            bindings = @QueueBinding(
//                    value = @Queue(name = "remove.queue"),
//                    exchange = @Exchange("topic.ex"),
//                    key = "product.remove"
//            )
//    )
//
//    public void remove(Integer productId) throws IOException {
//
//}
